import requests
from api.stock_info import mr_licence
from dao.company_employee_dao import CompanyEmployee

"""
历届高管成员
API接口：http://api.mairui.club/hscp/ljgg/股票代码(如000001)/您的licence
备用接口：http://api1.mairui.club/hscp/ljgg/股票代码(如000001)/您的licence
包年版接口：专用服务器(API接口前缀为 http://y.mairui.club)
钻石版接口：专用服务器(API接口前缀为 http://v.mairui.club)
接口说明：根据《股票列表》得到的股票代码获取上市公司的历届高管成员名单。
数据更新：每天15:30开始更新，次日凌晨3点前完成
请求频率：1分钟20次 | 包年版1分钟3千次 | 钻石版1分钟6千次
返回格式：标准Json格式      [{},...{}]
"""


def get_manager(stock_code):
    api_url = "http://api.mairui.club/hscp/ljgg/{0}/{1}".format(stock_code, mr_licence)
    response = requests.get(api_url)
    if response.status_code == 200:
        return response.json()
    else:
        return None


"""
历届董事会成员
API接口：http://api.mairui.club/hscp/ljds/股票代码(如000001)/您的licence
备用接口：http://api1.mairui.club/hscp/ljds/股票代码(如000001)/您的licence
包年版接口：专用服务器(API接口前缀为 http://y.mairui.club)
钻石版接口：专用服务器(API接口前缀为 http://v.mairui.club)
接口说明：根据《股票列表》得到的股票代码获取上市公司的历届董事会成员名单。
数据更新：每天15:30开始更新，次日凌晨3点前完成
请求频率：1分钟20次 | 包年版1分钟3千次 | 钻石版1分钟6千次
返回格式：标准Json格式      [{},...{}]
"""


def get_board_member(stock_code):
    api_url = "http://api.mairui.club/hscp/ljds/{0}/{1}".format(stock_code, mr_licence)
    response = requests.get(api_url)
    if response.status_code == 200:
        return response.json()
    else:
        return None


"""
历届监事会成员
API接口：http://api.mairui.club/hscp/ljjj/股票代码(如000001)/您的licence
备用接口：http://api1.mairui.club/hscp/ljjj/股票代码(如000001)/您的licence
包年版接口：专用服务器(API接口前缀为 http://y.mairui.club)
钻石版接口：专用服务器(API接口前缀为 http://v.mairui.club)
接口说明：根据《股票列表》得到的股票代码获取上市公司的历届监事会成员名单。
数据更新：每天15:30开始更新，次日凌晨3点前完成
请求频率：1分钟20次 | 包年版1分钟3千次 | 钻石版1分钟6千次
返回格式：标准Json格式      [{},...{}]
"""


def get_supervisor_member(stock_code):
    api_url = "http://api.mairui.club/hscp/ljjj/{0}/{1}".format(stock_code, mr_licence)
    response = requests.get(api_url)
    if response.status_code == 200:
        return response.json()
    else:
        return None


if __name__ == '__main__':
    stock_code = "000001"
    results = get_board_member(stock_code)
    print(results)
    CompanyEmployee.insert_or_update(stock_code, results, 3)
